package com.ada;

import io.reactivex.Observable;
import io.reactivex.subjects.ReplaySubject;

public class ObservableApp {

    public static void main(String[] args) {

//        ReplaySubject.amb()
//        Observable.from(names).subscribe(new Action1<String>() {
//
//            @Override
//            public void call(String s) {
//                System.out.println("Hello " + s + "!");
//            }
//
//        });
    }
}
